import { useUserStore, usePrivateNewsStore, useAllUsersStore } from '@/stores'
const userStore = useUserStore()
const privateNewsStore = usePrivateNewsStore()
const allUsersStore = useAllUsersStore()
console.log(userStore.userName)
const ws2 = new WebSocket(
  `ws://8.130.47.180:5173/messageServerSingle/${userStore.userName}/111`
)
ws2.onopen = function () {
  console.log('WebSocket2{私聊} 连接已经建立。')
}
// 收到消息
ws2.onmessage = function (event) {
  console.log('收到2号私聊的服务器消息：', event)
  console.log('收到2号私聊服务器消息 data：')
  const dataJson = JSON.parse(event.data)
  console.log(dataJson)
  // 是对话消息,加入对话仓库
  if (dataJson.content) {
    console.log('正打算加入++++++++++++++')
    console.log(privateNewsStore)
    console.log(privateNewsStore.addPrivateNews)
    console.log('正要加的消息')
    console.log(dataJson)
    console.log(dataJson.fromUser)
    console.log(userStore.userName)
    console.log('@@@@@@@@@@@@@@@@@@@@@@@@@@@@@')
    //消息是我发出的，记录在案
    if (dataJson.fromUser == userStore.userName||dataJson.fromUser==userStore.book) {
      privateNewsStore.addPrivateNews(dataJson)
      console.log('加入完成以后的----------')
      console.log(privateNewsStore.privateNewsList)
      console.log(222)
      return
    }
    // 消息发出者不是正在聊天的对面 拦截掉,并且给提示
    else if (dataJson.fromUser != userStore.book&&
      dataJson.toUser==userStore.userName) {
      console.log('allUsersStore.allUnreadMessage')
      console.log(allUsersStore.allUnreadMessage)
      console.log('allUsersStore.allUnreadMessage[dataJson.fromUser]')
      console.log(allUsersStore.allUnreadMessage[dataJson.fromUser])
      if (!allUsersStore.allUnreadMessage[dataJson.fromUser])
        allUsersStore.allUnreadMessage[dataJson.fromUser] = 0
      allUsersStore.allUnreadMessage[dataJson.fromUser] =
        Number(allUsersStore.allUnreadMessage[dataJson.fromUser]) + 1
      console.log('allUsersStore.allUnreadMessage[dataJson.fromUser]')
      console.log(allUsersStore.allUnreadMessage[dataJson.fromUser])
      console.log(111)
    }
  }
  //const res = JSON.parse(event.data)
  //console.log('解析以后的服务器消息：', res)
}
ws2.onerror = function (event) {
  console.error('WebSocket2{私聊} 连接出现错误：', event)
}
ws2.onclose = function () {
  console.log('WebSocket2{私聊} 连接已经关闭。')
}
export default ws2
